package cn.neo.hhmq.client;

import lombok.AllArgsConstructor;

/**
 * 本地测试mq，一旦实现远程访问，此方法可以删除
 * mq for topic
 */
@AllArgsConstructor
public class HHMq {

//    private String topic;
//    // 队列:当前队列只能消费一次，后续待优化
//    private LinkedBlockingQueue<HHMessage> queue = new LinkedBlockingQueue<>();
//    private List<HHListener> listeners = new ArrayList<>();
//
//
//
//    public boolean send(HHMessage message) {
//        boolean offered = queue.offer(message);
//        listeners.forEach(listener->listener.onMessage(message));
//        return offered;
//    }
//
//    public HHMq(String topic) {
//        this.topic = topic;
//    }
//
//    // 拉模式获取消息
//    @SneakyThrows
//    public <T> HHMessage<T> poll(long timeout) {
//        return queue.poll(timeout, TimeUnit.MILLISECONDS);
//    }
//
//    public <T> void addListener(HHListener<T> listener) {
//        listeners.add(listener);
//    }
}
